package acs.offer.httpclient;

import java.util.HashMap;
import java.util.Map;

import com.alibaba.fastjson.JSON;

import acs.offer.client.ClientHandler;
import acs.offer.collection.Params;
import acs.offer.constant.Constant;
import acs.offer.constant.EventType;
import acs.offer.controller.MessageQueue;
import acs.offer.pojo.Message;
import acs.offer.pojo.TranstractDate;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.FullHttpRequest;

public class HttpClientHandler  extends SimpleChannelInboundHandler<FullHttpRequest> {
  static Channel channel=null;
  @Override
  protected void channelRead0(ChannelHandlerContext context, FullHttpRequest message) throws Exception {
      System.out.println("收到服务端数据");
  }
  

  //有新连接加入
  @Override
  public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
      channel = ctx.channel();
      System.out.println("保存时的线程名："+Thread.currentThread().getName());
//      channelGroup.add(channel);
  }

}

